package com.tedu.cn;

import us.codecraft.webmagic.ResultItems;
import us.codecraft.webmagic.Task;
import us.codecraft.webmagic.pipeline.Pipeline;

/**
 * 爬虫的数据持久化组件
 * 调用dao  把数据添加到数据库
 */
public class DataDao extends BaseDaoJdbc implements Pipeline {

    //爬虫数据持久化  sql
    private  String sql = "INSERT INTO information(title,author,content,type,time,source,readtotal) VALUES(?,?,?,?,?,?,?)";

    /**
     * resultItems 获取ReptileMain组件解析后数据 page.putField("bj",bj.text());
     * @param resultItems
     * @param task
     */
    public void process(ResultItems resultItems, Task task) {
        Object bj = resultItems.get("bj");
        Object currChnlCls = resultItems.get("currChnlCls");
        Object title_tex = resultItems.get("title_tex");
        Object time_tex = resultItems.get("time_tex");
        Object time_ly = resultItems.get("time_ly");
        Object trs_editor = resultItems.get("trs_editor");

       System.out.println("bj="+bj);

        //调用dao保存  异步的，不影响爬虫的效率
        //使用jdbc保存数据库
        // 加载驱动--获取连接--获取执行器--执行sql--关闭连接
        //执行sql   写一个jdbc工具类（增删改查（查询使用java的反射机制来做），查询也可以不用做）
        // 自己想想  怎么设计一个数据库----党建信息表
        //调用父类更新数据库的方法。。。。。
        update(sql,"标题","作者","内容","类型","2021/5/18","四川花园",0);

    }
}
